type net/http/internal/http2.serverConn
85 uses
net/http/internal/http2 (current package)
server.go#L88: testHookOnPanic func(sc *serverConn, panicVal any) (rePanic bool)
server.go#L94: activeConns map[*serverConn]struct{}
server.go#L101: func (s *Server) registerConn(sc *serverConn) {
server.go#L110: func (s *Server) unregisterConn(sc *serverConn) {
server.go#L152: s.activeConns = make(map[*serverConn]struct{})
server.go#L240: var newf func(*serverConn)
server.go#L243: newf, _ = opts.Context.Value(NewConnContextKey).(func(*serverConn))
server.go#L256: func (s *Server) serveConn(c net.Conn, opts *ServeConnOpts, newf func(*serverConn)) {
server.go#L261: sc := &serverConn{
server.go#L397: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L405: type serverConn struct {
server.go#L479: func (sc *serverConn) writeSchedIgnoresRFC7540() bool {
server.go#L492: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L500: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L514: sc *serverConn
server.go#L539: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L540: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L541: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L542: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L546: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L573: func (sc *serverConn) setConnState(state ConnState) {
server.go#L577: func (sc *serverConn) vlogf(format string, args ...any) {
server.go#L583: func (sc *serverConn) logf(format string, args ...any) {
server.go#L631: func (sc *serverConn) condlogf(err error, format string, args ...any) {
server.go#L650: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L686: func (sc *serverConn) readFrames() {
server.go#L718: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L728: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L735: func (sc *serverConn) stopShutdownTimer() {
server.go#L742: func (sc *serverConn) notePanic() {
server.go#L757: func (sc *serverConn) serve(conf Config) {
server.go#L880: case func(*serverConn):
server.go#L906: func (sc *serverConn) handlePingTimer(lastFrameReadTime time.Time) {
server.go#L947: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L948: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L949: func (sc *serverConn) onReadIdleTimer() { sc.sendServeMsg(readIdleTimerMsg) }
server.go#L950: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L952: func (sc *serverConn) sendServeMsg(msg any) {
server.go#L965: func (sc *serverConn) readPreface() error {
server.go#L1002: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1049: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1069: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1133: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1200: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1268: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1324: func (sc *serverConn) startGracefulShutdown() {
server.go#L1347: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1351: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1365: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1370: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1381: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1438: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1493: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1517: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1553: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1572: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1616: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1644: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1688: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1702: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1799: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L1865: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L1988: func (sc *serverConn) upgradeRequest(req *ServerRequest) {
server.go#L2041: func (sc *serverConn) checkPriority(streamID uint32, p PriorityParam) error {
server.go#L2052: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L2068: func (sc *serverConn) processPriorityUpdate(f *PriorityUpdateFrame) error {
server.go#L2081: func (sc *serverConn) newStream(id, pusherID uint32, state streamState, priority PriorityParam) *stream {
server.go#L2116: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *ServerRequest, error) {
server.go#L2197: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *ServerRequest, error) {
server.go#L2229: func (sc *serverConn) newResponseWriter(st *stream) *responseWriter {
server.go#L2250: func (sc *serverConn) scheduleHandler(st *stream, rw *responseWriter, req *ServerRequest, handler func(*ResponseWriter, *ServerRequest)) error {
server.go#L2271: func (sc *serverConn) handlerDone() {
server.go#L2300: func (sc *serverConn) runHandler(rw *responseWriter, req *ServerRequest, handler func(*ResponseWriter, *ServerRequest)) {
server.go#L2347: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2379: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2396: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2406: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2417: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2422: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2446: conn *serverConn
server.go#L2495: conn *serverConn
server.go#L2724: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L2750: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L3065: func (sc *serverConn) startPush(msg *startPushRequest) {
server.go#L3212: func (sc *serverConn) countError(name string, err error) error {